package learn2workqueues

import utils.RabbitMqUtils

/**

 @author HSH

 @create 2022-01-06 10:45

 */
class Task01 {
    private static final String QUEUE_NAME = "hello"

    static void main(String[] args) {
        def channel = RabbitMqUtils.getChannel()
        /****
         * 生成一个队列
         * 1.队列名称
         * 2.队列里的消息是否持久化 默认消息存储在内存中
         * 3.该队列是否只供一个消费者进行消费 是否进行共享 true 可以多个消费者消费
         * 4.是否自动删除 最后一个消费者断开连接以后 该队列是否自动删除 true 自动删除
         * 5.其他参数
         *
         */
        channel.queueDeclare(QUEUE_NAME,false,false,false,null)
        def scanner = new Scanner(System.in)
        while (scanner.hasNext()){
            String message = scanner.next();
            channel.basicPublish("",QUEUE_NAME,null,message.getBytes())
            println "消息发送完成"
        }
    }
}
